package com.pingan.haofang.searchcloud.common.fetch;

import com.pingan.haofang.searchcloud.common.dto.PageDTO;

/**
 * 流式抓取接口
 *
 * @param <E>
 * @author LUYI374
 * @date 2017年3月23日
 * @since 1.0.0
 */
public interface StreamFetcher<E> {

    /**
     * 抓取结果集
     *
     * @param pageNo
     * @param pageSize
     * @return
     */
    public PageDTO<E> fetch(int pageNo, int pageSize);

    /**
     * 抓取结果集
     *
     * @param pageNo    页码
     * @param pageSize  每页大小
     * @param lastMaxId 上一次最大ID，用于优化查询
     * @return
     */
    PageDTO<E> fetch(int pageNo, int pageSize, Long lastMaxId);
}
